#include <sys/ipc.h> // ipc: Inter-Process Communicate
#include <sys/shm.h>
#include <cstring>
#include <unistd.h>
#include "comm.hpp"

class Init
{
public:
    Init()
    {
        bool r = MakeFifo();
        if (!r)
            return;

        key_t key = GetKey();
        std::cout << "key: " << ToHex(key) << std::endl;
        // key vs shmid
        // shmid：应用这个共享内存的时候，我们使用shmid来进行shmid的唯一性！ -> FILE*
        // key：不要在应用层使用，只用来在内核中标识shmid的唯一性(内核使用)！ -> fd
        shmid = CreatShm(key);
        std::cout << "shmid: " << shmid << std::endl;

        std::cout << "开始将shm映射到进程的地址空间中" << std::endl;
        s = (char *)shmat(shmid, nullptr, 0);

        fd = open(filename.c_str(), O_RDONLY);
    }
    ~Init()
    {
        shmdt(s);
        std::cout << "开始将shm从进程地址空间中移除" << std::endl;

        shmctl(shmid, IPC_RMID, nullptr); 
        std::cout << "开始将shm从OS中删除" << std::endl;
        close(fd);
        unlink(filename.c_str());
    }

public:
    int shmid;
    int fd;
    char *s;
};

int main()
{
    Init init;
    // TODO
    while (true)
    {
        // wait,等别人给你发消息，让你读在读
        int code = 0;
        ssize_t sz = read(init.fd, &code, sizeof(code));
        if (sz > 0)
        {
            // 直接读取的
            std::cout << "共享内存的内容：" << init.s << std::endl;
            sleep(1);
        }
        else if (0 == sz)
        {
            break;
        }
    }

    return 0;
}
